# -*- coding:utf-8 -*-
# @Author: shenyuyu
# @Time: 2023/6/21 10:27
# @File: test.py
from pyspark import SparkConf, SparkContext

if __name__ == "__main__":
    conf = SparkConf().setAppName("test").setMaster("local[*]")
    sc = SparkContext(conf=conf)
    collect = sc.parallelize([1, 2, 3, 4, 5]).map(lambda x: x + 10).collect()
    print(collect)